package com.cmb.lk50.sink.kafka;

import com.cmb.lk50.pojo.AccessInfo;

/**
 * Author       : 蒋俊钊 80256973
 * Date         : 2020/8/20
 * Copyright    (C) ChinaMerchantsBank
 */
public class IpKeyGenerator implements KafkaKeyGenerator<AccessInfo> {

    @Override
    public String getRecordKey(AccessInfo log) {
        return log.getHostIp();
    }
}
